package spring.cloud.tasks.client.item_task_processor;

import java.util.concurrent.atomic.AtomicLong;


public class TaskProcessingStatistics {
    private AtomicLong taskFetchNum = new AtomicLong(0);
    private AtomicLong fetchFetchDataCount = new AtomicLong(0);
    //
    private AtomicLong taskSuccessNum = new AtomicLong(0);
    private AtomicLong taskFailNum = new AtomicLong(0);
    //
    private AtomicLong spendTime = new AtomicLong(0);


    public void addFetchTaskFetchNum(long value) {
        this.taskFetchNum.addAndGet(value);
    }

    public void addFetchDataCount(long value) {
        this.fetchFetchDataCount.addAndGet(value);
    }

    public void addTaskSuccessNum(long value) {
        this.taskSuccessNum.addAndGet(value);
    }

    public void addTaskFailNum(long value) {
        this.taskFailNum.addAndGet(value);
    }

    public void addSpendTime(long value) {
        this.spendTime.addAndGet(value);
    }


}
